package cn.classg.rabbitmq.mq;

import org.springframework.amqp.core.MessagePostProcessor;

public interface MqMessage<T> {

    /**
     * 发送消息
     *
     * @param message 消息体
     */
    default void product(T message) {
    }

    /**
     * 发送消息
     *
     * @param message              消息体
     * @param messagePostProcessor 消息后置处理
     */
    default void product(T message, MessagePostProcessor messagePostProcessor) {
    }
}
